//package com.xiao.websocket;
//
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component;
//
//import javax.websocket.*;
//import javax.websocket.server.ServerEndpoint;
//import java.io.IOException;
//
///**
// * @Describe: websocket服务(tomcat实现)
// * @Author: yangchengxiao
// * @Date: 2021/6/11 15:30
// */
//
//@Slf4j
//@Component
//@ServerEndpoint("/websocket/server")
//public class WebSocketServer {
//
//    @OnOpen
//    public void onOpen(Session session){
//        log.info("已建立连接………………, sessionId: {}", session.getId());
//    }
//
//    @OnClose
//    public void onclose(Session session){
//        log.info("已关闭连接………………, sessionId: {}", session.getId());
//    }
//
//    @OnMessage
//    public void onMessage(String message, Session session) throws IOException {
//        log.info("接收到消息, message: {}, sessionId: {}", message, session.getId());
//        session.getBasicRemote().sendText(message);
//    }
//
//    @OnError
//    public void onError(Session session, Throwable e){
//        log.error("连接发生错误, sessionId: {}", session.getId(), e);
//    }
//}
